package internal

import (
	"ycxp/mq/conf"
	"ycxp/ysjzx/rabbitmq"
)

type Module struct {
	*rabbitmq.RabbitMq
}

func (m *Module) OnInit() {
	m.RabbitMq = &rabbitmq.RabbitMq{
		AmqpUrl:       conf.MqConf.AmqpUrl,       //amqp地址
		ConnectionNum: conf.MqConf.ConnectionNum, //连接数
		ChannelNum:    conf.MqConf.ChannelNum,    //每个连接的channel数量

		//ExchangeList: MqConf.ExchangeList, // 交换机类型
		//QueueList:    MqConf.QueueList,    // 交换机类型
	}
}
